//package com.gzcstec.product.rabbitmq;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.core.AmqpTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
///**
// * mq消息发生测试
// */
//@RestController
//@Slf4j
//@RequestMapping("/mq")
//public class MqController {
//
//    @Autowired
//    private AmqpTemplate amqpTemplate;
//
//    /**
//     * amqpTemplate第一种方式，直接通过queue进行发送和接收
//     * @return
//     */
//    @GetMapping("/msg")
//    public String sendMsg() {
//        amqpTemplate.convertAndSend("product"  , "发送消息");
//        return "ok";
//    }
//
//    /**
//     * amqpTemplate第二种方式，使用queue绑定exchange，通过key区分不同消息
//     * @return
//     */
//    @GetMapping("/msg/fruit")
//    public String sendFruit() {
//        amqpTemplate.convertAndSend("orderEx"  , "fruit", "发送消息");
//        return "fruit";
//    }
//
//    /**
//     * amqpTemplate第二种方式，使用queue绑定exchange，通过key区分不同消息
//     * @return
//     */
//    @GetMapping("/msg/computer")
//    public String sendComputer() {
//        amqpTemplate.convertAndSend("orderEx"  , "computer", "发送消息");
//        return "computer";
//    }
//
//}
